package com.jms;

import javax.jms.*;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

/**
 * Created by simon on 16-6-13.
 */
public class test7 {
    /**
     *
     *  TemporaryQueue和TemporaryTopic，从字面上就可以看出它们是“临时”的目的地。可以通过Session来创建，例如：
     TemporaryQueue replyQueue = session.createTemporaryQueue();

     虽然它们是由Session来创建的，但是它们的生命周期确实整个Connection。如果在一个Connection上创建了两个Session，
     则一个Session创建的TemporaryQueue或TemporaryTopic也可以被另一个Session访问。那如果这两个Session是由不同的Connection创建，
     则一个Session创建的TemporaryQueue不可以被另一个Session访问。
     另外，它们的主要作用就是用来指定回复目的地， 即作为JMSReplyTo。
     在下面的例子中，先创建一个Connection，然后创建两个Session，其中一个Session创建了一个TemporaryQueue，
     另一个Session在这个TemporaryQueue上读取消息。
     *
     * **/

    public static void main(String[] args) throws Exception {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
        factory.setPassword("admin");
        factory.setUserName("admin");
        factory.setBrokerURL("tcp://localhost:61616");
        Connection connection = factory.createConnection();
        connection.start();


        Queue queue = new ActiveMQQueue("Test7Queue");
        final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //使用session创建一个TemporaryQueue。
        TemporaryQueue replyQueue = session.createTemporaryQueue();

        //接收消息，并回复到指定的Queue中（即replyQueue）
        MessageConsumer comsumer = session.createConsumer(queue);
        comsumer.setMessageListener(new MessageListener() {
            public void onMessage(Message m) {
                try {
                    System.out.println("Get Message: " + ((TextMessage) m).getText());
                    MessageProducer producer = session.createProducer(m.getJMSReplyTo());
                    producer.send(session.createTextMessage("ReplyMessage"));
                } catch (JMSException e) {
                }
            }
        });

        //使用同一个Connection创建另一个Session，来读取replyQueue上的消息。
        Session session2 = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer replyComsumer = session2.createConsumer(replyQueue);
        replyComsumer.setMessageListener(new MessageListener() {
            public void onMessage(Message m) {
                try {
                    System.out.println("Get reply: " + ((TextMessage) m).getText());
                } catch (JMSException e) {
                }
            }
        });

        MessageProducer producer = session.createProducer(queue);
        TextMessage message = session.createTextMessage("SimpleMessage");
        message.setJMSReplyTo(replyQueue);
        producer.send(message);
    }
}
